//package com.wushijia.mq; /**
// * Created by pc on 2017/11/7.
// */
//
//import com.aliyun.openservices.shade.com.alibaba.rocketmq.client.producer.DefaultMQProducer;
//import com.aliyun.openservices.shade.com.alibaba.rocketmq.client.producer.SendResult;
//import com.aliyun.openservices.shade.com.alibaba.rocketmq.common.message.Message;
//
///**
// * 消息队列生产者测试
// *
// * @author houyangyang
// * @create 2017-11-07 17:37
// **/
//public class ProducerTest {
//    public static void main(String[] args) {
//        DefaultMQProducer producer = new DefaultMQProducer("producer");
//        producer.setNamesrvAddr("127.0.0.1:9876");
//        // 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可
//        try {
//            producer.start();
//            int i = 0;
//            //循环发送消息
//            while(++i < 100){
//                Message msg = new Message( //
//                        // 在控制台创建的Topic，即该消息所属的Topic名称
//                        "PushTopic",
//                        // Message Tag,
//                        // 可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤
//                        "push",
//                        "1",
//                        // Message Body
//                        // 任何二进制形式的数据， MQ不做任何干预，
//                        // 需要Producer与Consumer协商好一致的序列化和反序列化方式
//                        "Hello MQ".getBytes());
//                // 设置代表消息的业务关键属性，请尽可能全局唯一，以方便您在无法正常收到消息情况下，可通过MQ控制台查询消息并补发
//                // 注意：不设置也不会影响消息正常收发
//                //msg.setKey("ORDERID_100");
//                // 发送消息，只要不抛异常就是成功
//                // 打印Message ID，以便用于消息发送状态查询
//                SendResult sendResult = producer.send(msg);
//                System.out.println("Send Message success. Message ID is: " + sendResult.getMsgId());
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }finally {
//            // 在应用退出前，可以销毁Producer对象
//            // 注意：如果不销毁也没有问题
//            producer.shutdown();
//        }
//    }
//}
